package high.concurrent.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import high.concurrent.model.TxMsg;
import org.apache.ibatis.annotations.Param;

import java.util.List;

public interface TxMsgMapper extends BaseMapper<TxMsg> {
    /**
     * 消息服务定期轮询，过期的“已发送”消息（过期一般是根据业务规则来自行调整，例如2min）（查已发送的定时器）
     * @param status 状态（0：待发送； 1：已发送）
     * @param verdueTime 轮询间隔
     * @return
     */
    List<TxMsg> selectOverdueMsg(@Param("status") int status, @Param("verdueTime") int verdueTime);
}
